package org.nanfang.procedure;

import java.util.concurrent.TimeUnit;

//定义一个线程类 实现模拟数据采集 - 利用
public class Procedure extends Thread{
    @Override
    public void run() {
        while (true){
            System.out.println("开始采集");
            //获取我们的终端标记
            boolean flag = Thread.currentThread().isInterrupted();
            if (flag){
                System.out.println("采集总，准备收尾");
                break;
            }
            try {
                //每隔两秒采集一次
                TimeUnit.SECONDS.sleep(2);
            } catch (InterruptedException e) {
//                throw new RuntimeException(e);
                //二次终端，把你清除的中断的标记重新设置为true便于推出
                Thread.currentThread().interrupt();
            }
        }
    }
}
